<?php
namespace Util\ChatPay;

require_once THINK_PATH . "Library/Util/ChatPay/lib/WxPay.Api.php";
use ChatPay\lib\WxPayApi;
use ChatPay\lib\WxPayOrderQuery;
require_once THINK_PATH . "Library/Util/ChatPay/lib/WxPay.Notify.php";
use ChatPay\lib\WxPayNotify;
use Util\ChatPay\Log;

abstract class PayNotifyBasic extends WxPayNotify{
    //查询订单
    public function Queryorder($transaction_id){
        $input = new WxPayOrderQuery();
        $input->SetTransaction_id($transaction_id);
        $result = WxPayApi::orderQuery($input);
       
        Log::DEBUG("query:" . json_encode($result));
        if (array_key_exists("return_code", $result)
            && array_key_exists("result_code", $result)
            && $result["return_code"] == "SUCCESS"
            && $result["result_code"] == "SUCCESS"
        ) {
            return true;
        }
        return false;
    }

    //重写回调处理函数
    public function NotifyProcess($data, &$msg){
        $logHandler= new CLogFileHandler("../logs/".date('Y-m-d').'.log');
        $log = Log::Init($logHandler, 15);
        Log::DEBUG("call back:" . json_encode($data));
        $notfiyOutput = array();
        if (!array_key_exists("transaction_id", $data)) {
            $msg = "输入参数不正确";
            return false;
        }
        //查询订单，判断订单真实性
        if (!$this->Queryorder($data["transaction_id"])) {
            $msg = "订单查询失败";
            return false;
        }
        switch ($this->overWriteCall($data)) {
            case 'TRUE':
                return true;
                break;
            case 'FALSE':
                return false;
                break;
            case 'NOTHING':
                break;
        }
    }

    abstract public function overWriteCall($data);
}